package io.mft.datasource.mq.rabbitmq.consumer;


import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;

import io.mft.datasource.mq.rabbitmq.MqDatasource;

/**
 * @说明： TODO
 * @类型名称：MqConnectionFactory
 * @创建者 ： 杨亮
 * @创建时间： 2019/11/5  14:31
 * @修改者 ： 杨亮
 * @修改时间： 2019/11/5  14:31
 */
public class MqConsumerConnectionFactory extends CachingConnectionFactory  {

    public MqConsumerConnectionFactory(MqDatasource datasource){
        super();
        this.setAddresses( datasource.getAddresses() );
        this.setUsername(  datasource.getUsername() );
        this.setPassword(  datasource.getPassword()  );
        this.setChannelCacheSize( datasource.getChannel() ) ;
    }

}
